import asyncio

import demo_job
import snail

# 设置事件循环
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)

# 使用事件循环执行任务
manager = snail.create_manager_on_loop(loop)
manager.register(demo_job.test_job_executor)
manager.register(demo_job.test_job_executor_failed)


# 执行事件循环
loop.run_forever()
